package com.fanshuai.spring.boot.kafkaTransaction.consuner.listener;

import org.apache.kafka.clients.consumer.ConsumerRecord;

public interface ConsumerListener {
    void beforeConsume(ConsumerRecord<String, String> record);
    void afterConsume(ConsumerRecord<String, String> record);

    int order();
}
